package com.zc.study.stream

import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment

object DataStreamDataSource {
  def main(args: Array[String]): Unit = {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    env.setStreamTimeCharacteristic()
  }
}
